package com.ktvme.core;

import com.ktvme.flink13.Flink1_13JobServiceImpl;

public class FlinkJobServiceFactory {
    
    public static AbstractFlinkJobService createFlinkJobService(String version, String url) {
        if ("1.13".equals(version)) {
            return new Flink1_13JobServiceImpl(url);
        }
        // 可以在这里添加其他版本的实现
        
        throw new IllegalArgumentException("Unsupported Flink version: " + version);
    }
} 